home *** CD-ROM | disk | FTP | other *** search
/ Internet Info 1994 March / Internet Info CD-ROM (Walnut Creek) (March 1994).iso / networking / ip / ka9q / alpha.arc / ICMPCMD.C < prev    next >
C/C++ Source or Header  |  1988-06-13  |  5KB  |  225 lines
  1. /* ICMP-related user commands */
  2. #include <stdio.h>
  3. #include "global.h"
  4. #include "icmp.h"
  5. #include "mbuf.h"
  6. #include "netuser.h"
  7. #include "internet.h"
  8. #include "timer.h"
  9. #include "ping.h"
  10.  
  11. int
  12. doicmpstat()
  13. {
  14.     extern struct icmp_errors icmp_errors;
  15.     extern struct icmp_stats icmp_stats;
  16.     extern char *icmptypes[];
  17.     register int i;
  18.  
  19.     printf("ICMP: chksum err %u no space %u icmp %u bdcsts %u\n",
  20.      icmp_errors.checksum,icmp_errors.nospace,icmp_errors.noloop,
  21.      icmp_errors.bdcsts);
  22.     printf("type  rcvd  sent\n");
  23.     for(i=0;i<ICMP_TYPES;i++){
  24.         if(icmp_stats.input[i] == 0 && icmp_stats.output[i] == 0)
  25.             continue;
  26.         printf("%-6u%-6u%-6u",i,icmp_stats.input[i],
  27.             icmp_stats.output[i]);
  28.         if(icmptypes[i] != NULLCHAR)
  29.             printf("  %s",icmptypes[i]);
  30.         printf("\n");
  31.     }
  32.     return 0;
  33. }
  34.  
  35. /* Hash table list heads */
  36. struct ping *ping[PMOD];
  37.  
  38. /* Counter for generating seq numbers */
  39. static int16 iclk;
  40.  
  41. /* Increment counter -- called by low level clock tick */
  42. icmpclk()
  43. {
  44.     iclk++;
  45. }
  46.  
  47. /* Send ICMP Echo Request packets */
  48. doping(argc,argv)
  49. int argc;
  50. char *argv[];
  51. {
  52.     int32 dest;
  53.     struct ping *add_ping(),*pp1;
  54.     register struct ping *pp;
  55.     void ptimeout();
  56.     int16 hval,hash_ping();
  57.     int i;
  58.     char *inet_ntoa();
  59.  
  60.     if(argc < 2){
  61.         printf("Host                Sent    Rcvd   %%   Avg RTT  Interval\n");
  62.         for(i=0;i<PMOD;i++){
  63.             for(pp = ping[i];pp != NULLPING;pp = pp->next){
  64.                 printf("%-16s",inet_ntoa(pp->remote));
  65.                 printf("%8lu%8lu",pp->count,pp->echoes);
  66.                 printf("%4lu%10lu%10lu\n",
  67.                  (long)pp->echoes * 100 / pp->count,
  68.                  pp->echoes != 0 ? 
  69.                  (long)pp->ttotal * MSPTICK / pp->echoes : 0,
  70.                  ((long)pp->timer.start * MSPTICK + 500) / 1000);
  71.             }
  72.         }
  73.         return 0;
  74.     }
  75.     if(strcmp(argv[1],"clear") == 0){
  76.         for(i=0;i<PMOD;i++){
  77.             for(pp = ping[i];pp != NULLPING;pp = pp1){
  78.                 pp1 = pp->next;
  79.                 del_ping(pp);
  80.             }
  81.         }
  82.         return 0;
  83.     }
  84.     if((dest = resolve(argv[1])) == 0){
  85.         printf("Host %s unknown\n",argv[1]);
  86.         return 1;
  87.     }
  88.     /* See if dest is already in table */
  89.     hval = hash_ping(dest);
  90.     for(pp = ping[hval]; pp != NULLPING; pp = pp->next){
  91.         if(pp->remote == dest){
  92.             break;
  93.         }
  94.     }
  95.     if(argc > 2){
  96.         /* Inter-ping time is specified; set up timer structure */
  97.         if(pp == NULLPING)
  98.             pp = add_ping(dest);
  99.         pp->timer.start = atoi(argv[2]) * (1000 / MSPTICK);
  100.         pp->timer.func = ptimeout;
  101.         pp->timer.arg = (char *)pp;
  102.         pp->remote = dest;
  103.         start_timer(&pp->timer);
  104.         pp->count++;
  105.         pingem(dest,iclk,REPEAT);
  106.     } else
  107.         pingem(dest,iclk,ONESHOT);
  108.  
  109.     return 0;
  110. }
  111.  
  112. /* Called by ping timeout */
  113. void
  114. ptimeout(p)
  115. char *p;
  116. {
  117.     register struct ping *pp;
  118.  
  119.     /* Send another ping */
  120.     pp = (struct ping *)p;
  121.     pp->count++;
  122.     pingem(pp->remote,iclk,REPEAT);
  123.     start_timer(&pp->timer);
  124. }
  125. /* Send ICMP Echo Request packet */
  126. static
  127. pingem(dest,seq,id)
  128. int32 dest;
  129. int16 seq;
  130. int16 id;
  131. {
  132.     struct mbuf *bp,*htonicmp();
  133.     struct icmp icmp;
  134.     extern struct icmp_stats icmp_stats;
  135.  
  136.     icmp_stats.output[ECHO]++;
  137.     icmp.type = ECHO;
  138.     icmp.code = 0;
  139.     icmp.args.echo.seq = seq;
  140.     icmp.args.echo.id = id;
  141.     if((bp = htonicmp(&icmp,NULLBUF)) == NULLBUF)
  142.         return 0;
  143.     return ip_send(ip_addr,dest,ICMP_PTCL,0,0,bp,len_mbuf(bp),0,0);
  144. }
  145.  
  146. /* Called with incoming Echo Reply packet */
  147. int
  148. echo_proc(source,dest,icmp)
  149. int32 source,dest;
  150. struct icmp *icmp;
  151. {
  152.     register struct ping *pp;
  153.     int16 hval,hash_ping();
  154.     int16 rtt;
  155.     char *inet_ntoa();
  156.  
  157.     rtt = iclk - icmp->args.echo.seq;
  158.     hval = hash_ping(source);
  159.     for(pp = ping[hval]; pp != NULLPING; pp = pp->next)
  160.         if(pp->remote == source)
  161.             break;
  162.     if(pp == NULLPING || icmp->args.echo.id != 1){
  163.         printf("%s: echo reply id %u seq %u, %lu ms\n",
  164.          inet_ntoa(source),
  165.          icmp->args.echo.id,icmp->args.echo.seq,
  166.          (long)rtt * MSPTICK);
  167.          fflush(stdout);
  168.     } else {
  169.         /* Repeated poll, just keep stats */
  170.         pp->ttotal += rtt;
  171.         pp->echoes++;
  172.     }
  173. }
  174. static
  175. int16
  176. hash_ping(dest)
  177. int32 dest;
  178. {
  179.     int16 hval;
  180.  
  181.     hval = (hiword(dest) ^ loword(dest)) % PMOD;
  182.     return hval;
  183. }
  184. /* Add entry to ping table */
  185. static
  186. struct ping *
  187. add_ping(dest)
  188. int32 dest;
  189. {
  190.     struct ping *pp;
  191.     int16 hval,hash_ping();
  192.  
  193.     pp = (struct ping *)calloc(1,sizeof(struct ping));
  194.     if(pp == NULLPING)
  195.         return NULLPING;
  196.  
  197.     hval = hash_ping(dest);
  198.     pp->prev = NULLPING;
  199.     pp->next = ping[hval];
  200.     if(pp->next != NULLPING)
  201.         pp->next->prev = pp;
  202.     ping[hval] = pp;
  203.     return pp;
  204. }
  205. /* Delete entry from ping table */
  206. static
  207. del_ping(pp)
  208. struct ping *pp;
  209. {
  210.     int16 hval,hash_ping();
  211.  
  212.     stop_timer(&pp->timer);
  213.  
  214.     if(pp->next != NULLPING)
  215.         pp->next->prev = pp->prev;
  216.     if(pp->prev != NULLPING) {
  217.         pp->prev->next = pp->next;
  218.     } else {
  219.         hval = hash_ping(pp->remote);
  220.         ping[hval] = pp->next;
  221.     }
  222.     free((char *)pp);    
  223. }
  224.  
  225.